package cn.lesaas.esb.poc.test;

import org.apache.camel.builder.RouteBuilder;

public class RulerRoute extends RouteBuilder{
	@Override
	public void configure() throws Exception {
		//TODO 记录定时任务 持久化 考虑使用数据库
		//定时任务规则
		from("direct:test")
			.split(body()).parallelProcessing()
				.log("Processing message[${property.CamelSplitIndex}]")
				.to("direct:Parallel")
			.end();
		
		//执行任务
		from("direct:Parallel").log("thread: ${threadname}").to("");
	}

}
